var net = require('net');

var HOST = '127.0.0.1';
var PORT = 8085;

// 创建一个TCP服务器实例，调用listen函数开始监听指定端口
// 传入net.createServer()的回调函数将作为”connection“事件的处理函数
// 在每一个“connection”事件中，该回调函数接收到的socket对象是唯一的
var conns = [];
//
net.createServer(function(sock) {

    //记录每一个链接的信息
    conns.push(sock);
    //console.log(conns);

    // 我们获得一个连接 - 该连接自动关联一个socket对象
    console.log('CONNECTED: ' +
        sock.remoteAddress + ':' + sock.remotePort);

    // 为这个socket实例添加一个"data"事件处理函数
    sock.on('data', function(data) {
        // console.log(data)
        console.log('DATA ' + sock.remoteAddress + ': ' + data);
        var msg = data.toString();
        var header = msg.substr(0,10);
        var body = msg.substr(10);

        var header_r = header;
        var body_r = body.toUpperCase();
        // 回发该数据，客户端将收到来自服务端的数据
        sock_w = conns[0];
        if(sock_w){
            sock.write(header_r+body_r);
        }
    });

    // 为这个socket实例添加一个"close"事件处理函数
    sock.on('close', function(data) {
        console.log('CLOSED: ' +
            sock.remoteAddress + ' ' + sock.remotePort);
    });

}).listen(PORT, HOST);

console.log('Server listening on ' + HOST +':'+ PORT);